f5dcb44b2267dce05395d5c50fb2afeef04abf6d,src/main/java/uk/sky/cqlmigrate/CqlMigratorImpl.java,CqlMigratorImpl,migrate,#Session#String#Collection#,72
Before Change
clusterHealth.check();
CassandraLockingMechanism cassandraLockingMechanism = new CassandraLockingMechanism(session, keyspace);
Lock lock = Lock.acquire(cassandraLockingMechanism, lockConfig);
LOGGER.info("Loading cql files from {}", directories);
CqlPaths paths = CqlPaths.create(directories);
KeyspaceBootstrapper keyspaceBootstrapper = new KeyspaceBootstrapper(session, keyspace, paths);
SchemaUpdates schemaUpdates = new SchemaUpdates(session, keyspace);
SchemaLoader schemaLoader = new SchemaLoader(session, keyspace, schemaUpdates, paths);
keyspaceBootstrapper.bootstrap();
schemaUpdates.initialise();
schemaLoader.load();
lock.release();
}
/**
After Change
CassandraLockingMechanism cassandraLockingMechanism = new CassandraLockingMechanism(session, keyspace);
Lock lock = new Lock(cassandraLockingMechanism, lockConfig);
lock.lock();
LOGGER.info("Loading cql files from {}", directories);
CqlPaths paths = CqlPaths.create(directories);